Node / meshtastic / Meshtastic-Android / files / feature / node / src / commonMain / kotlin / org / meshtastic / feature / node / detail / NodeDetailViewModel.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.feature.node.detail

Tff7b72import T7ee787androidx.lifecycle.SavedStateHandle

Tff7b72import T7ee787androidx.lifecycle.ViewModel

Tff7b72import T7ee787androidx.lifecycle.viewModelScope

Tff7b72import T7ee787kotlinx.coroutines.ExperimentalCoroutinesApi

Tff7b72import T7ee787kotlinx.coroutines.channels.Channel

Tff7b72import T7ee787kotlinx.coroutines.flow.Flow

Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow

Tff7b72import T7ee787kotlinx.coroutines.flow.StateFlow

Tff7b72import T7ee787kotlinx.coroutines.flow.combine

Tff7b72import T7ee787kotlinx.coroutines.flow.distinctUntilChanged

Tff7b72import T7ee787kotlinx.coroutines.flow.flatMapLatest

Tff7b72import T7ee787kotlinx.coroutines.flow.flowOf

Tff7b72import T7ee787kotlinx.coroutines.flow.receiveAsFlow

Tff7b72import T7ee787kotlinx.coroutines.launch

Tff7b72import T7ee787org.koin.core.annotation.KoinViewModel

Tff7b72import T7ee787org.meshtastic.core.domain.usecase.session.EnsureRemoteAdminSessionUseCase

Tff7b72import T7ee787org.meshtastic.core.domain.usecase.session.EnsureSessionResult

Tff7b72import T7ee787org.meshtastic.core.domain.usecase.session.ObserveRemoteAdminSessionStatusUseCase

Tff7b72import T7ee787org.meshtastic.core.model.Node

Tff7b72import T7ee787org.meshtastic.core.model.NodeAddress

Tff7b72import T7ee787org.meshtastic.core.model.SessionStatus

Tff7b72import T7ee787org.meshtastic.core.navigation.Route

Tff7b72import T7ee787org.meshtastic.core.navigation.SettingsRoute

Tff7b72import T7ee787org.meshtastic.core.repository.QueryController

Tff7b72import T7ee787org.meshtastic.core.resources.Res

Tff7b72import T7ee787org.meshtastic.core.resources.UiText

Tff7b72import T7ee787org.meshtastic.core.resources.connect_radio_for_remote_admin

Tff7b72import T7ee787org.meshtastic.core.resources.remote_admin_unreachable

Tff7b72import T7ee787org.meshtastic.core.ui.util.SnackbarManager

Tff7b72import T7ee787org.meshtastic.core.ui.viewmodel.stateInWhileSubscribed

Tff7b72import T7ee787org.meshtastic.feature.node.component.NodeMenuAction

Tff7b72import T7ee787org.meshtastic.feature.node.domain.usecase.GetNodeDetailsUseCase

Tff7b72import T7ee787org.meshtastic.feature.node.metrics.EnvironmentMetricsState

Tff7b72import T7ee787org.meshtastic.feature.node.model.LogsType

Tff7b72import T7ee787org.meshtastic.feature.node.model.MetricsState

T8b949e/** UI state for the Node Details screen. */

Tf0883e@androidx.compose.runtime.Stable

Tff7b72data Tff7b72class T56d364NodeDetailUiStateTb4b4b4(

Tff7b72val Te6edf3nodeTb4b4b4: Te6edf3Node? Tff7b72= Tff7b72nullTb4b4b4,

Tff7b72val Te6edf3nodeNameTb4b4b4: Te6edf3UiText Tff7b72= Te6edf3UiTextTb4b4b4.Te6edf3DynamicStringTb4b4b4(Ta5d6ff"Ta5d6ff"Tb4b4b4)Tb4b4b4,

Tff7b72val Te6edf3ourNodeTb4b4b4: Te6edf3Node? Tff7b72= Tff7b72nullTb4b4b4,

Tff7b72val Te6edf3metricsStateTb4b4b4: Te6edf3MetricsState Tff7b72= Te6edf3MetricsStateTb4b4b4.Te6edf3EmptyTb4b4b4,

Tff7b72val Te6edf3environmentStateTb4b4b4: Te6edf3EnvironmentMetricsState Tff7b72= Te6edf3EnvironmentMetricsStateTb4b4b4(Tb4b4b4)Tb4b4b4,

Tff7b72val Te6edf3availableLogsTb4b4b4: Te6edf3SetTff7b72<Te6edf3LogsTypeTff7b72> Tff7b72= Te6edf3emptySetTb4b4b4(Tb4b4b4)Tb4b4b4,

Tff7b72val Te6edf3lastTracerouteTimeTb4b4b4: Tffa657Long? Tff7b72= Tff7b72nullTb4b4b4,

Tff7b72val Te6edf3lastRequestNeighborsTimeTb4b4b4: Tffa657Long? Tff7b72= Tff7b72nullTb4b4b4,

Tff7b72val Te6edf3sessionStatusTb4b4b4: Te6edf3SessionStatus Tff7b72= Te6edf3SessionStatusTb4b4b4.Te6edf3NoSessionTb4b4b4,

Tff7b72val Te6edf3isEnsuringSessionTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72falseTb4b4b4,

Tb4b4b4)

Tff7b72internal Tff7b72object T56d364NodeDetailUiTextResolver Tb4b4b4{

Tff7b72var Te6edf3resolveTb4b4b4: Te6edf3suspend Tb4b4b4(Te6edf3UiTextTb4b4b4) Tff7b72-Tff7b72> Tffa657String Tff7b72= Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3resolveTb4b4b4(Tb4b4b4) Tb4b4b4}

Tb4b4b4}

T8b949e/**

* ViewModel for the Node Details screen, coordinating data from the node database, mesh logs, and radio configuration.

*/

Tf0883e@OptInTb4b4b4(Te6edf3ExperimentalCoroutinesApiTff7b72::Te6edf3classTb4b4b4)

Tf0883e@KoinViewModel

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffLongParameterListTa5d6ff"Tb4b4b4)

Tff7b72class T56d364NodeDetailViewModelTb4b4b4(

Tff7b72private Tff7b72val Te6edf3savedStateHandleTb4b4b4: Te6edf3SavedStateHandleTb4b4b4,

Tff7b72private Tff7b72val Te6edf3nodeManagementActionsTb4b4b4: Te6edf3NodeManagementActionsTb4b4b4,

Tff7b72private Tff7b72val Te6edf3nodeRequestActionsTb4b4b4: Te6edf3NodeRequestActionsTb4b4b4,

Tff7b72private Tff7b72val Te6edf3queryControllerTb4b4b4: Te6edf3QueryControllerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3getNodeDetailsUseCaseTb4b4b4: Te6edf3GetNodeDetailsUseCaseTb4b4b4,

Tff7b72private Tff7b72val Te6edf3ensureRemoteAdminSessionTb4b4b4: Te6edf3EnsureRemoteAdminSessionUseCaseTb4b4b4,

Tff7b72private Tff7b72val Te6edf3observeRemoteAdminSessionStatusTb4b4b4: Te6edf3ObserveRemoteAdminSessionStatusUseCaseTb4b4b4,

Tff7b72private Tff7b72val Te6edf3snackbarManagerTb4b4b4: Te6edf3SnackbarManagerTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3ViewModelTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3nodeIdFromRouteTb4b4b4: Tffa657Int? Tff7b72= Te6edf3savedStateHandleTb4b4b4.Te6edf3getTff7b72<Tffa657IntTff7b72>Tb4b4b4(Ta5d6ff"Ta5d6ffdestNumTa5d6ff"Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3manualNodeId Tff7b72= Te6edf3MutableStateFlowTff7b72<Tffa657Int?Tff7b72>Tb4b4b4(Tff7b72nullTb4b4b4)

Tff7b72private Tff7b72val Te6edf3activeNodeId Tff7b72=

Te6edf3combineTb4b4b4(Te6edf3MutableStateFlowTb4b4b4(Te6edf3nodeIdFromRouteTb4b4b4)Tb4b4b4, Te6edf3manualNodeIdTb4b4b4) Tb4b4b4{ Te6edf3fromRouteTb4b4b4, Te6edf3manual Tff7b72-Tff7b72> Te6edf3manual Tff7b72?: Te6edf3fromRoute Tb4b4b4}

Tb4b4b4.Te6edf3distinctUntilChangedTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3isEnsuringSession Tff7b72= Te6edf3MutableStateFlowTb4b4b4(Tff7b72falseTb4b4b4)

Tff7b72private Tff7b72val Te6edf3sessionStatusFlow Tff7b72=

Te6edf3activeNodeIdTb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3nodeId Tff7b72-Tff7b72>

Tff7b72if Tb4b4b4(Te6edf3nodeId Tff7b72=Tff7b72= Tff7b72nullTb4b4b4) Te6edf3flowOfTb4b4b4(Te6edf3SessionStatusTb4b4b4.Te6edf3NoSessionTb4b4b4) Tff7b72else Te6edf3observeRemoteAdminSessionStatusTb4b4b4(Te6edf3nodeIdTb4b4b4)

Tb4b4b4}

T8b949e/** One-shot navigation events from session-bearing actions (e.g. successful remote-admin opens). */

Tff7b72private Tff7b72val Te6edf3_navigationEvents Tff7b72= Te6edf3ChannelTff7b72<Te6edf3RouteTff7b72>Tb4b4b4(Te6edf3capacity Tff7b72= Te6edf3ChannelTb4b4b4.Te6edf3BUFFEREDTb4b4b4)

Tff7b72val Te6edf3navigationEventsTb4b4b4: Te6edf3FlowTff7b72<Te6edf3RouteTff7b72> Tff7b72= Te6edf3_navigationEventsTb4b4b4.Te6edf3receiveAsFlowTb4b4b4(Tb4b4b4)

T8b949e/** Primary UI state stream, combining identity, metrics, and global device metadata. */

Tff7b72val Te6edf3uiStateTb4b4b4: Te6edf3StateFlowTff7b72<Te6edf3NodeDetailUiStateTff7b72> Tff7b72=

Te6edf3activeNodeId

Tb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3nodeId Tff7b72-Tff7b72>

Tff7b72if Tb4b4b4(Te6edf3nodeId Tff7b72=Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{

Te6edf3flowOfTb4b4b4(Te6edf3NodeDetailUiStateTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3combineTb4b4b4(Te6edf3getNodeDetailsUseCaseTb4b4b4(Te6edf3nodeIdTb4b4b4)Tb4b4b4, Te6edf3sessionStatusFlowTb4b4b4, Te6edf3isEnsuringSessionTb4b4b4) Tb4b4b4{

Te6edf3baseTb4b4b4,

Te6edf3sessionStatusTb4b4b4,

Te6edf3ensuringTb4b4b4,

Tff7b72-Tff7b72>

Te6edf3baseTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3sessionStatus Tff7b72= Te6edf3sessionStatusTb4b4b4, Te6edf3isEnsuringSession Tff7b72= Te6edf3ensuringTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

Tb4b4b4.Te6edf3stateInWhileSubscribedTb4b4b4(Te6edf3initialValue Tff7b72= Te6edf3NodeDetailUiStateTb4b4b4(Tb4b4b4)Tb4b4b4)

Tff7b72fun Td2a8ffstartTb4b4b4(Te6edf3nodeIdTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3manualNodeIdTb4b4b4.Te6edf3value Tff7b72!Tff7b72= Te6edf3nodeIdTb4b4b4) Tb4b4b4{

Te6edf3manualNodeIdTb4b4b4.Te6edf3value Tff7b72= Te6edf3nodeId

Tb4b4b4}

Tb4b4b4}

T8b949e/** Dispatches high-level node management actions like removal, muting, or favoriting. */

Tff7b72fun Td2a8ffhandleNodeMenuActionTb4b4b4(Te6edf3actionTb4b4b4: Te6edf3NodeMenuActionTb4b4b4, Te6edf3onAfterRemoveTb4b4b4: Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657Unit Tff7b72= Tb4b4b4{Tb4b4b4}Tb4b4b4) Tb4b4b4{

Tff7b72when Tb4b4b4(Te6edf3actionTb4b4b4) Tb4b4b4{

Tff7b72is Te6edf3NodeMenuActionTb4b4b4.Te6edf3Remove Tff7b72-Tff7b72>

Te6edf3nodeManagementActionsTb4b4b4.Te6edf3requestRemoveNodeTb4b4b4(Te6edf3viewModelScopeTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4, Te6edf3onAfterRemoveTb4b4b4)

Tff7b72is Te6edf3NodeMenuActionTb4b4b4.Te6edf3Ignore Tff7b72-Tff7b72> Te6edf3nodeManagementActionsTb4b4b4.Te6edf3requestIgnoreNodeTb4b4b4(Te6edf3viewModelScopeTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4)

Tff7b72is Te6edf3NodeMenuActionTb4b4b4.Te6edf3Mute Tff7b72-Tff7b72> Te6edf3nodeManagementActionsTb4b4b4.Te6edf3requestMuteNodeTb4b4b4(Te6edf3viewModelScopeTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4)

Tff7b72is Te6edf3NodeMenuActionTb4b4b4.Te6edf3Favorite Tff7b72-Tff7b72> Te6edf3nodeManagementActionsTb4b4b4.Te6edf3requestFavoriteNodeTb4b4b4(Te6edf3viewModelScopeTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4)

Tff7b72is Te6edf3NodeMenuActionTb4b4b4.Te6edf3RequestUserInfo Tff7b72-Tff7b72>

Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3nodeRequestActionsTb4b4b4.Te6edf3requestUserInfoTb4b4b4(Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3numTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3long_nameTb4b4b4)

Tb4b4b4}

Tff7b72is Te6edf3NodeMenuActionTb4b4b4.Te6edf3RequestNeighborInfo Tff7b72-Tff7b72>

Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3nodeRequestActionsTb4b4b4.Te6edf3requestNeighborInfoTb4b4b4(Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3numTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3long_nameTb4b4b4)

Tb4b4b4}

Tff7b72is Te6edf3NodeMenuActionTb4b4b4.Te6edf3RequestPosition Tff7b72-Tff7b72>

Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3nodeRequestActionsTb4b4b4.Te6edf3requestPositionTb4b4b4(Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3numTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3long_nameTb4b4b4)

Tb4b4b4}

Tff7b72is Te6edf3NodeMenuActionTb4b4b4.Te6edf3RequestTelemetry Tff7b72-Tff7b72>

Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3nodeRequestActionsTb4b4b4.Te6edf3requestTelemetryTb4b4b4(Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3numTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3long_nameTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3typeTb4b4b4)

Tb4b4b4}

Tff7b72is Te6edf3NodeMenuActionTb4b4b4.Te6edf3TraceRoute Tff7b72-Tff7b72>

Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3nodeRequestActionsTb4b4b4.Te6edf3requestTracerouteTb4b4b4(Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3numTb4b4b4, Te6edf3actionTb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3long_nameTb4b4b4)

Tb4b4b4}

Tff7b72else Tff7b72-Tff7b72> Tb4b4b4{Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

T8b949e/**

* Re-fetch device metadata (firmware/edition/role) for [destNum]. Refreshes the session passkey as a side effect.

*/

Tff7b72fun Td2a8ffrefreshMetadataTb4b4b4(Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4) Tff7b72= Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{ Te6edf3queryControllerTb4b4b4.Te6edf3refreshMetadataTb4b4b4(Te6edf3destNumTb4b4b4) Tb4b4b4}

T8b949e/**

* Ensure a remote-admin session passkey is fresh, then request navigation to the remote-admin screen. Surfaces a

* snackbar with the appropriate guidance on [EnsureSessionResult.Disconnected] or [EnsureSessionResult.Timeout].

*/

Tff7b72fun Td2a8ffopenRemoteAdminTb4b4b4(Te6edf3destNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{

T8b949e// Atomic check-and-flip prevents a double-tap from queuing two passkey exchanges + two navigation events.

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3isEnsuringSessionTb4b4b4.Te6edf3compareAndSetTb4b4b4(Te6edf3expect Tff7b72= Tff7b72falseTb4b4b4, Te6edf3update Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4) Tff7b72return

Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{

Tff7b72try Tb4b4b4{

Tff7b72when Tb4b4b4(Te6edf3ensureRemoteAdminSessionTb4b4b4(Te6edf3destNumTb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3EnsureSessionResultTb4b4b4.Te6edf3AlreadyActiveTb4b4b4,

Te6edf3EnsureSessionResultTb4b4b4.Te6edf3RefreshedTb4b4b4,

Tff7b72-Tff7b72> Te6edf3_navigationEventsTb4b4b4.Te6edf3trySendTb4b4b4(Te6edf3SettingsRouteTb4b4b4.Te6edf3SettingsTb4b4b4(Te6edf3destNumTb4b4b4)Tb4b4b4)

Te6edf3EnsureSessionResultTb4b4b4.Te6edf3Disconnected Tff7b72-Tff7b72> Tb4b4b4{

Tff7b72val Te6edf3text Tff7b72= Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3connect_radio_for_remote_admin

Te6edf3snackbarManagerTb4b4b4.Te6edf3showSnackbarTb4b4b4(Te6edf3NodeDetailUiTextResolverTb4b4b4.Te6edf3resolveTb4b4b4(Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3textTb4b4b4)Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Te6edf3EnsureSessionResultTb4b4b4.Te6edf3Timeout Tff7b72-Tff7b72>

Te6edf3snackbarManagerTb4b4b4.Te6edf3showSnackbarTb4b4b4(

Te6edf3NodeDetailUiTextResolverTb4b4b4.Te6edf3resolveTb4b4b4(Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3remote_admin_unreachableTb4b4b4)Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tb4b4b4} Tff7b72finally Tb4b4b4{

Te6edf3isEnsuringSessionTb4b4b4.Te6edf3value Tff7b72= Tff7b72false

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

Tff7b72fun Td2a8ffsetNodeNotesTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3notesTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{

Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{ Te6edf3nodeManagementActionsTb4b4b4.Te6edf3setNodeNotesTb4b4b4(Te6edf3nodeNumTb4b4b4, Te6edf3notesTb4b4b4) Tb4b4b4}

Tb4b4b4}

T8b949e/** Returns the type-safe navigation route for a direct message to this node. */

Tff7b72fun Td2a8ffgetDirectMessageRouteTb4b4b4(Te6edf3nodeTb4b4b4: Te6edf3NodeTb4b4b4, Te6edf3ourNodeTb4b4b4: Te6edf3Node?Tb4b4b4)Tb4b4b4: Tffa657String Tb4b4b4{

Tff7b72val Te6edf3hasPKC Tff7b72= Te6edf3ourNodeTff7b72?.Te6edf3hasPKC Tff7b72=Tff7b72= Tff7b72true Tff7b72&Tff7b72& Te6edf3nodeTb4b4b4.Te6edf3hasPKC

Tff7b72val Te6edf3channel Tff7b72= Tff7b72if Tb4b4b4(Te6edf3hasPKCTb4b4b4) Te6edf3NodeAddressTb4b4b4.Te6edf3PKC_CHANNEL_INDEX Tff7b72else Te6edf3nodeTb4b4b4.Te6edf3channel

Tff7b72return Ta5d6ff"Tffd700${Te6edf3channelTffd700}Tffd700${Te6edf3nodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3idTffd700}Ta5d6ff"

Tb4b4b4}

Tb4b4b4}